package pku;



public class DefaultMessageFactory {

     public ByteMessage createBytesMessageToTopic(String topic, byte[] body) {
         DefaultMessage defaultBytesMessage = new DefaultMessage(body);
        defaultBytesMessage.putHeaders(MessageHeader.TOPIC, topic);
        return defaultBytesMessage;
    }

    public ByteMessage createBytesMessageToQueue(String queue, byte[] body) {
        DefaultMessage defaultBytesMessage = new DefaultMessage(body);
        defaultBytesMessage.putHeaders(MessageHeader.QUEUE, queue);
        return defaultBytesMessage;
    }
}
